import { redis } from './db';
const Task = require('data.task');

var g_io;

const startRedis = () => new Task((rej, res) => {
    (async () => {
        while(true) {
            var msg = await redis.blpop('notice_message',5);
            if(msg && g_io){
                console.log('startRedis-',msg);
                g_io.in('backuser').emit('message',msg);
            }
        }
        //return msg;
    })().then(res).catch(rej)

    // redis.blpop('notice_message',5).then(result=>{
    //     console.log(result);
    //     res(result);
    // }).catch(rej);
    
})

const initSocketIo = (io)=>{
    //socket连接.
    io.on( "connection", function( socket ){
        console.log( "一个新连接" ); 
        socket.join('backuser');
    });
    g_io = io;
};

export {
    startRedis,
    initSocketIo
}



